package com.basic

import org.apache.spark.sql.SparkSession

object CreateDataFrame {
  def main(args: Array[String]): Unit = {
    // 1. 先创建及SparkSession
    val sparkSession = SparkSession.builder()
      .appName("CreateDataFrame")
      .master("local[2]")
      .getOrCreate()
    // 2. 通过SparkSession创建DF
    val dataFrame = sparkSession.read.json("E:\\ZJJ_SparkSQL\\demo01\\src\\main\\resources\\users.json")
    // 3. 对DF做操作(sql)
    // 3.1 创建临时表
    dataFrame.createOrReplaceTempView("user")
    dataFrame.cache()
    // 3.2 查询临时表
    sparkSession.sql("select * from user").show()
    // 4. 关闭SparkSession
    sparkSession.stop()


  }

}
